package com.gjy.design.observer.disruptor;

/**
 * @author gjy
 * @version 1.0
 * @since 2025-11-08 09:14:35
 */
public interface Subscriber {

    String getId();

    void onMessage(MessageEvent event);

    void onError(Throwable throwable);

}
